package syan.kafkap.controller;

import lombok.extern.slf4j.Slf4j;
import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.web.bind.annotation.*;
import syan.kafkap.kafka.EsKafkaMessageSender;

/**
 * @author CHENTAIWEN
 * @create 2022/8/9 14:49
 */
@Slf4j
@RestController
@RequestMapping("/demo")
public class DemoController {
    @Autowired
    private EsKafkaMessageSender sender;

    /**
     * kafka发送消息
     * @author sfy
     * @Date 2020/9/22 3:50 下午
     */
    @PostMapping("/testKafkaMessageSend")
    public void testKafkaMessageSend(@RequestParam("message")String message) {
        sender.sendToDefaultChannel(message);
        sender.sendToDefaultChannel(message);
        sender.sendToDefaultChannel(message);
        sender.sendToDefaultChannel(message);
    }

    /**
     * kafka发送消息
     * @author sfy
     * @Date 2020/9/22 3:50 下午
     */
    @PostMapping("/testKafkaMessageSend2")
    public void testKafkaMessageSend2(@RequestParam("message")String message) {
        sender.sendToAlarmChannel(message);
    }

}